const express = require('express')
const app = express()

var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";
let fs = require('fs')
var hh    // 字符串类型
// 定义局部生效的中间件
const mw1 = (req, res, next)=>{
    MongoClient.connect(url, function(err, db) {
        if (err) throw err;
        // console.log("数据库已创建!");
        var dbase = db.db("runoob");   // 创建的数据库名【runoob】
        dbase.collection("site").find().toArray((err, result)=>{
            if(err) throw err
            // 调用 a() 方法，把result赋值给全局变量 arr
            a(JSON.stringify(result))
            res.send(JSON.stringify(result))
            db.close();
        }) 
    });
}

function a(aa){
    hh = aa;
    // console.log("bbb"+hh);
    // 写入文件
    fs.writeFile('../查询的数据.json',hh,(err)=>{
        if(err) console.log(err);
        console.log("文件创建成功");
    })
}


// 创建路由
app.get('/',mw1,(req) => {
    res.send('我是路由')
})

//配置端口
app.listen(80, ()=>{
    console.log("端口号为：http://127.0.0.1");
})
